package calvin.study.rabbitmq.service;

import java.util.Map;

import org.springframework.messaging.handler.annotation.Headers;

import com.rabbitmq.client.Channel;

/**
 * 消费服务
 * @author wh
 *
 */
public interface IConsumeService {

	//public void sendMsg(String message) throws Exception;

	public void sendMsg(String message, @Headers Map<String, Object> headers, Channel channel) throws Exception;
}
